# 使用celery的步骤
# 1. 导入模块
from celery import Celery
from ihome.libs.yuntongxun.sms import CPP # 导入云通信发送短信的模块
# 2.实例化Celery对象并指导消息队列的地址
# 定义celery对象,ihome是celery的名字，根据业务场景而定，当前做的是爱家租房，所以是ihome
# broker="redis://127.0.0.1:6379/1":指定消息中间人的链接地址
celery_app = Celery("ihome",broker="redis://127.0.0.1:6379/1")
# 3. 编写客户端处理代码
@celery_app.task # 当前函数可以发送到任务队列中，发送的是函数名及其参数
def send_sms(to,datas,temp_id):
    """以异步的形式发送短信"""
    cpp = CPP()
    # 发送短信后没有处理返回值问题，因此待会儿会返回None
    cpp.send_message(temp_id,to,datas)
